package com.zmx.job.admin.core.scheduler;

import com.zmx.job.admin.core.thread.JobSchedulerHelper;
import com.zmx.job.admin.core.thread.JobQueueHelper;
import lombok.extern.slf4j.Slf4j;

/**
 * @Description: 任务定时器
 * @ClassName: MallJobScheduler
 * @Author zhaomxr
 * @Date 2021-12-20 15:58
 */
@Slf4j
public class MallJobScheduler {

    public void init() {
        // 开始扫描当前要执行任务
        JobSchedulerHelper.getInstance().start();
        // 开始分发任务到客户端
        JobQueueHelper.getInstance().start();
    }

    public void destory() {
        // 停止扫描待执行任务
        JobSchedulerHelper.getInstance().toStop();
        // 停止分发任务到客户端
        JobQueueHelper.getInstance().toStop();
    }
}
